0fed4d43bd36dfa9e250fcf5c02d02c1ae36b13b,src/test/java/com/continuuity/runtime/FlowTest.java,FlowTest,testFlow,#,70
Before Change
@Test
public void testFlow() throws Exception {
final CConfiguration configuration = CConfiguration.create();
configuration.set(Constants.CFG_APP_FABRIC_TEMP_DIR, System.getProperty("java.io.tmpdir") + "/app/temp");
configuration.set(Constants.CFG_APP_FABRIC_OUTPUT_DIR, System.getProperty("java.io.tmpdir")
+ "/app/archive" + UUID.randomUUID());
Injector injector = Guice.createInjector(new DataFabricModules().getInMemoryModules(),
new BigMamaModule(configuration));
injector.getInstance(DiscoveryService.class).startAndWait();
LocalLocationFactory lf = new LocalLocationFactory();
Location deployedJar = lf.create(
JarFinder.getJar(WordCountApp.class, TestHelper.getManifestWithMainClass(WordCountApp.class))
);
deployedJar.deleteOnExit();
ListenableFuture<?> p = TestHelper.getLocalManager(configuration).deploy(DefaultId.ACCOUNT, deployedJar);
ProgramRunnerFactory runnerFactory = injector.getInstance(ProgramRunnerFactory.class);
final ApplicationWithPrograms app = (ApplicationWithPrograms)p.get();
List<ProgramController> controllers = Lists.newArrayList();
for (final Program program : app.getPrograms()) {
ProgramRunner runner = runnerFactory.create(ProgramRunnerFactory.Type.valueOf(program.getProcessorType().name()));
After Change
@Test
public void testFlow() throws Exception {
TestHelper.getInjector().getInstance(DiscoveryService.class).startAndWait();
final ApplicationWithPrograms app = TestHelper.deployApplicationWithManager(WordCountApp.class);
ProgramRunnerFactory runnerFactory = TestHelper.getInjector().getInstance(ProgramRunnerFactory.class);
List<ProgramController> controllers = Lists.newArrayList();
for (final Program program : app.getPrograms()) {
ProgramRunner runner = runnerFactory.create(ProgramRunnerFactory.Type.valueOf(program.getProcessorType().name()));
controllers.add(runner.run(program, new ProgramOptions() {
@Override
public String getName() {
return program.getProgramName();
}
@Override
public Arguments getArguments() {
return new BasicArguments();
}
@Override
public Arguments getUserArguments() {
return new BasicArguments();
}
}));
}
TimeUnit.SECONDS.sleep(1);
OperationExecutor opex = TestHelper.getInjector().getInstance(OperationExecutor.class);
OperationContext opCtx = new OperationContext(DefaultId.ACCOUNT.getId(),
app.getAppSpecLoc().getSpecification().getName());